const mysql = require('mysql');
const { MYSQL_CONF } = require('../conf/db');
const con = mysql.createConnection(MYSQL_CONF); // 创建连接对象

con.connect(); // 开始连接

function exec(sql) { // 统一执行函数
  const promise = new Promise((res, rej) => {
    con.query(sql, (err, result) => {
      if (err) {
        rej(err)
        return
      }
      res(result)
    })
  })
  return promise
}

module.exports = {
  exec
}